package com.itdfq.delay.constant;

/**
 * @Author: QianMo
 * @Date: 2021/10/21 10:30
 * @Description:
 */
public class RabbitMqConstant {

    /***************立即消费开始*****************/
    /**
     * 立即消费的exchange
     */
    public static final String IMMEDIATE_EXCHANGE = "exchange.delay.immediate";

    /**
     * 队列
     */
    public static final String IMMEDIATE_QUEUE = "queue.delay.immediate";
    /**
     * 立即消费的routing-key 名称
     */
    public static final String IMMEDIATE_ROUTING_KEY = "routingkey.delay.immediate";
    /***************立即消费结束*****************/


    /***********************固定的延时消费******************************/
    public static final Integer DELAY_TIME = 10 * 1000;

    /**
     *  延时消费的队列名称
     */
    public static final String DELAY_QUEUE = "queue.wechat.delay";

    /**
     *  延时消费的exchange
     */
    public static final String DELAY_EXCHANGE = "exchange.wechat.delay";

    /**
     *  延时消费的routing-key名称
     */
    public static final String DELAY_ROUTING_KEY = "routingkey.wechat.delay";

    /***********************可变时间延时|消费*************************/

    public static final String DELAY_VARIABLE_ROUTING_KEY = "delay.variable.routing_key";
    public static final String DELAY_VARIABLE_EXCHANGE_KEY = "delay.variable.exchange_key";
    public static final String DELAY_VARIABLE_QUEUE_KEY = "delay.variable.queue_key";
}
